
class Topics {
    constructor(params) {
        this.topics = {}
    }

    addTopic(name) {
        if (undefined === this.topics[name]) {
            this.topics[name] = new Rx.Subject();
        }
    }

    getTopic(name) {
        if (undefined === this.topics[name]) {
            this.topics[name] = new Rx.Subject();
        }
        return this.topics[name]
    }



}

export { Topics }